package org.lwd.datalink.domain.enent;

import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
import org.lwd.datalink.domain.media.parameter.hbase.HBaseMediaSrcParameter;
import org.lwd.datalink.domain.media.parameter.zk.ZkMediaSrcParameter;
import org.lwd.datalink.event.CallbackEvent;
import org.lwd.datalink.utils.FutureCallback;

/**
 * @Author: weidong.lin
 */
@ToString
@Getter
@Setter
public class HBaseColumnsEvent extends CallbackEvent {

    private HBaseMediaSrcParameter hbaseParameter;

    private ZkMediaSrcParameter zkParameter;

    private String tableName;

    /**
     * 从hbases服务端取出指定的条数，再根据返回的这些记录数解析hbase表结构
     */
    private int onceFetchAmount;

    public HBaseColumnsEvent(FutureCallback event, HBaseMediaSrcParameter hbaseParameter,
                             ZkMediaSrcParameter zkParameter, String tableName, int onceFetchAmount) {
        super(event);
        this.hbaseParameter = hbaseParameter;
        this.zkParameter = zkParameter;
        this.tableName = tableName;
        this.onceFetchAmount = onceFetchAmount;
    }
}
